package com.etl.dataflow.executor.core;

/**
 * @author dx
 * @since 2022/4/21
 */
public interface Writer {
    void startWrite();

    void setOnWriteFinishedListener(OnWriteFinishedListener listener);

    void setOnFatalErrorListener(OnFatalErrorListener listener);

    void setAfterWriteInterceptor(AbstractAfterWriteInterceptor interceptor);

    void exit();

    interface OnWriteFinishedListener {
        void onFinished();
    }

    interface OnFatalErrorListener {
        void onError(Exception e);
    }
}
